package avicit.bdp.dcs.job.dto;

import avicit.bdp.dcs.task.dto.TableMappingDto;

import javax.persistence.Entity;
import java.util.Date;
import java.util.List;

/**
 * @金航数码科技有限责任公司
 * @作者：developer
 * @邮箱：developer@avic-digital.com
 * @创建时间： 2021-11-02 10:17
 * @类说明：
 * @修改记录：
 */
@Entity
public class KafkaJobDto {

    private static final long serialVersionUID = 1L;

    private String id;
    private String name;
    private Integer job_type;
    private String created_by;
    private Date creation_date;
    private String last_updated_by;
    private Date last_update_date;
    private KafkaDatasource src_datasource;
    private KafkaDatasource dst_datasource;
    private List<TableMappingDto> selected_table;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getJob_type() {
        return job_type;
    }

    public void setJob_type(Integer job_type) {
        this.job_type = job_type;
    }

    public String getCreated_by() {
        return created_by;
    }

    public void setCreated_by(String created_by) {
        this.created_by = created_by;
    }

    public Date getCreation_date() {
        return creation_date;
    }

    public void setCreation_date(Date creation_date) {
        this.creation_date = creation_date;
    }

    public String getLast_updated_by() {
        return last_updated_by;
    }

    public void setLast_updated_by(String last_updated_by) {
        this.last_updated_by = last_updated_by;
    }

    public Date getLast_update_date() {
        return last_update_date;
    }

    public void setLast_update_date(Date last_update_date) {
        this.last_update_date = last_update_date;
    }

    public KafkaDatasource getSrc_datasource() {
        return src_datasource;
    }

    public void setSrc_datasource(KafkaDatasource src_datasource) {
        this.src_datasource = src_datasource;
    }

    public KafkaDatasource getDst_datasource() {
        return dst_datasource;
    }

    public void setDst_datasource(KafkaDatasource dst_datasource) {
        this.dst_datasource = dst_datasource;
    }

    public List<TableMappingDto> getSelected_table() {
        return selected_table;
    }

    public void setSelected_table(List<TableMappingDto> selected_table) {
        this.selected_table = selected_table;
    }

    public class KafkaDatasource{
        private String id;
        private String name;
        private String type;
        private String type_id;
        private String connection_params;
        private Integer structure;
        private Integer project_type;

        public String getId() {
            return id;
        }

        public void setId(String id) {
            this.id = id;
        }

        public String getName() {
            return name;
        }

        public void setName(String name) {
            this.name = name;
        }

        public String getType() {
            return type;
        }

        public void setType(String type) {
            this.type = type;
        }

        public String getType_id() {
            return type_id;
        }

        public void setType_id(String type_id) {
            this.type_id = type_id;
        }

        public String getConnection_params() {
            return connection_params;
        }

        public void setConnection_params(String connection_params) {
            this.connection_params = connection_params;
        }

        public Integer getStructure() {
            return structure;
        }

        public void setStructure(Integer structure) {
            this.structure = structure;
        }

        public Integer getProject_type() {
            return project_type;
        }

        public void setProject_type(Integer project_type) {
            this.project_type = project_type;
        }
    }

}